package com.gi.product.message;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

import java.security.PrivateKey;

/**
 * Created by lancf on 2019/7/12.
 *
 * 不知道是不是升级的原因,@Input和@Output的值是不一样的
 */
public interface StreamClient {
    String INMSG = "in-my-Message";
    String OUTMSG = "out-my-Message";

    @Input(StreamClient.INMSG)
    SubscribableChannel input();

    @Output(StreamClient.OUTMSG)
    MessageChannel output();
}
